package cn.iocoder.yudao.module.shop.service.order.handler;

import cn.iocoder.yudao.module.member.api.level.MemberLevelApi;
import cn.iocoder.yudao.module.member.api.point.MemberPointApi;
import cn.iocoder.yudao.module.member.enums.MemberExperienceBizTypeEnum;
import cn.iocoder.yudao.module.member.enums.point.MemberPointBizTypeEnum;
import cn.iocoder.yudao.module.shop.dal.dataobject.order.ShopOrderDO;
import cn.iocoder.yudao.module.shop.dal.dataobject.order.ShopOrderItemDO;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.List;


/**
 * 会员积分、等级的 {@link ShopOrderHandler} 实现类
 *
 * @author 曹建伟
 */

@Component
public class MemberPointShopOrderHandler implements ShopOrderHandler{

    @Resource
    private MemberPointApi memberPointApi;
    @Resource
    private MemberLevelApi memberLevelApi;


    @Override
    public void afterPayOrder(ShopOrderDO order, List<ShopOrderItemDO> shopOrderItems) {
        // 增加用户积分（订单赠送）
        addPoint(order.getMemberId(), order.getPayPrice(), MemberPointBizTypeEnum.ORDER_GIVE,
                order.getId());

        // 增加用户经验
        memberLevelApi.addExperience(order.getMemberId(), order.getPayPrice(),
                MemberExperienceBizTypeEnum.ORDER_GIVE.getType(), String.valueOf(order.getId()));
    }

    @Override
    public void rollbackOrder(ShopOrderDO order, List<ShopOrderItemDO> orderItems){
        if(!order.getWalletCharge()){
            return;
        }

        reducePoint(order.getMemberId(), order.getPayPrice(), MemberPointBizTypeEnum.ORDER_GIVE_ROLLBACK, order.getId());
        memberLevelApi.reduceExperience(order.getMemberId(), order.getPayPrice(), MemberExperienceBizTypeEnum.ORDER_GIVE_ROLLBACK.getType(), String.valueOf(order.getId()));
    }

    /**
     * 添加用户积分
     * <p>
     * 目前是支付成功后，就会创建积分记录。
     * <p>
     * 业内还有两种做法，可以根据自己的业务调整：
     * 1. 确认收货后，才创建积分记录
     * 2. 支付 or 下单成功时，创建积分记录（冻结），确认收货解冻或者 n 天后解冻
     *
     * @param userId  用户编号
     * @param point   增加积分数量
     * @param bizType 业务编号
     * @param bizId   业务编号
     */
    protected void addPoint(Long userId, Integer point, MemberPointBizTypeEnum bizType, Long bizId) {
        if (point != null && point > 0) {
            memberPointApi.addPoint(userId, point, bizType.getType(), String.valueOf(bizId));
        }
    }

    protected void reducePoint(Long userId, Integer point, MemberPointBizTypeEnum bizType, Long bizId){
        if (point != null && point > 0) {
            memberPointApi.reducePoint(userId, point, bizType.getType(), String.valueOf(bizId));
        }
    }
}
